// 引入 操作msyql数据库 mysql模块
var mysql = require("mysql");

let sql = (database,sql) => {
    // 创建mysql连接配置项
    var connection = mysql.createConnection({
		// 主机号，一般是localhost或者127.0.0.1
		host: 'localhost',
		// mysql数据库用户名
		user: 'root',
		// msyql数据库密码
		password: '123456',
		// 网站的数据库名称
		database: database
	})
    // 创建mysql连接 
    connection.connect()

    // 封装mysql
    /*

    @sql  sql表示sql增删改查的语句，比如 select * from user;

    */
    return new Promise((resolve, reject) => {
        connection.query(sql, function (error, results, fields) {
            if (error) {
                reject(error);
            } else {
                console.log(`---mysql数据库连接成功---`);
                resolve(results);
            }
        })
        // 断开数据库的链接
        connection.end();
    })
}

module.exports = sql;



